# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.dwd_terminal_sign_all_detail_new_dt import jms_dwd__dwd_terminal_sign_all_detail_new_dt

oss__network_retention_summary_sum = BashOperator(
    task_id='oss__network_retention_summary_sum',
    email=['houwenlong@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/network_retention_summary_sum/execute.sh',
    execution_timeout=timedelta(minutes=50),
    sla=timedelta(hours=8)
)

oss__network_retention_summary_sum << [
    jms_dwd__dwd_terminal_sign_all_detail_new_dt
]
